package com.example.demo.service;

import org.example.annotation.ConsumerKafkaMessage;
import org.example.annotation.ProducerKafkaMessage;

/**
 *
 * @author youshang
 * @date 2021/02/18 18:09
 **/
public interface IndexService {

    @ProducerKafkaMessage("index")
    String producerIndexMessage(String record);

    @ConsumerKafkaMessage(value = "index",consumerGroup = "dev-index")
    String consumerIndexMessage(String record);
}
